package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 只是一个单纯的函数式接口(回调函数) 收到消息后要处理消息时 调用的方法
 */
@FunctionalInterface
public interface Consumer {
    // Delivery 的意思的"投递" 这个方法的预期 是服务器每次收到消息之后 来调用
    //通过这个方法 将消息推送给队列的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
